package com.caipiao.lottery.dbwarpper;

/**
 * @author GaoFeng
 * @time 2014年1月13日
 */

import com.caipiao.lottery.log.TraceLogger;
import com.caipiao.lottery.task.keepline.CookieItem;
import com.caipiao.util.db.DBHelper;
import org.slf4j.Logger;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;

public class P_API_TASK {
    public static final String DB_NAME = "danmu";

    public static Logger logger = TraceLogger.DB;

    /**
     * 查询需要处理的cookie
     * @return
     */
    @SuppressWarnings({"finally"})
    public static boolean findCookieList(String msg_id,
                                         String readCount, String expireDate, List<CookieItem> oResult) {
        boolean flag = false;

        Connection conn = null;
        ResultSet rs = null;
        NamedParameterStatement ps = null;
        String sql = "";

        try {
            conn = DBHelper.Instance().getConnection(msg_id, DB_NAME, logger); // 连接池获取链接
            if (null == conn) {
                throw new Exception("获取数据库连接异常,:DBPoolName" + DB_NAME);
            }
            sql = " select "
                    + " id," +
                    "type," +
                    "cookie," +
                    "userName," +
                    "pwd," +
                    "creatTime," +
                    "lastRunTime "
                    + " from tb_cookie " +
                    " WHERE lastRunTime < :expireDate " +
                    " and userId = 0 " +
                    " limit " + readCount + " ";
            logger.info(msg_id + " - 查询需要处理的cookie[readCount:" + readCount + "; " +
                    "expireDate:" + expireDate + "]");
            ps = new NamedParameterStatement(conn, sql);
            ps.setString("expireDate", expireDate);
            rs = ps.executeQuery();
            while (rs != null && rs.next()) {
                CookieItem cookie = new CookieItem();
                cookie.msgId = msg_id;

                cookie.id = rs.getString("id");
                cookie.type = rs.getString("type");
                cookie.userName = rs.getString("userName");
                cookie.pwd = rs.getString("pwd");
                cookie.cookie = rs.getString("cookie");
                cookie.creatTime = rs.getString("creatTime");
                cookie.lastRunTime = rs.getString("lastRunTime");
                oResult.add(cookie);
            }

            flag = true;
        } catch (SQLException e) {
            e.printStackTrace();
            logger.error(msg_id + ":" + DB_NAME + " - " + sql + "执行异常:"
                    + e);
        } catch (Exception e) {

            logger.error(msg_id + ":" + DB_NAME + " - " + sql + "执行异常:"
                    + e);
        } finally {

            DBHelper.Instance().closeResource(conn, ps, rs); // 释放资源
            return flag;
        }
    }

    /**
     * 修改cookie最后执行时间
     * @return
     */
    @SuppressWarnings("finally")
    public static boolean prUpdateLastRunTime(String msg_id, String id, String timeStr) {
        boolean flag = false;

        Connection conn = null;
        ResultSet rs = null;
        String sql = "";
        NamedParameterStatement ps = null;
        try {
            conn = DBHelper.Instance().getConnection(msg_id, DB_NAME, logger); // 连接池获取链接
            if (null == conn) {
                throw new Exception("获取数据库连接异常,:DBPoolName" + DB_NAME);
            }

            sql = " update tb_cookie t " +
                    " set t.lastRunTime = :timeStr " +
                    " where t.id = :id";

            ps = new NamedParameterStatement(conn, sql);
            ps.setString("id", id);
            ps.setString("timeStr", timeStr);
            int count = ps.executeUpdate();

            if (count > 0) {
                flag = true;// 记录数据库输出参数
                logger.info(msg_id + " - 修改task任务[id:" + id + "]执行状态为成功,完成");
            }

        } catch (Exception e) {
            e.printStackTrace();
            logger.error(msg_id + ":" + DB_NAME + " - " + sql + "执行异常:"
                    + e);
        } finally {
            DBHelper.Instance().closeResource(conn, ps, rs); // 释放资源
            return flag;
        }
    }


//	/**
//	 * 查询过期的用户上传图片列表
//	 * @param msg_id
//	 * @param readCount
//	 * @param expireDate 过期日期点 yyyyMMdd
//	 * @param oResult
//	 * @return
//	 */
//	@SuppressWarnings("finally")
//	public static boolean find_expire_user_up_img_list(String msg_id,
//			String readCount, String expireDate, List<UserUpImg> oResult) {
//		boolean flag = false;
//
//		Connection conn = null;
//		ResultSet rs = null;
//		String sql = "";
//		NamedParameterStatement ps = null;
//		try {
//			conn = DBHelper.Instance().getConnection(msg_id, DB_NAME, logger); // 连接池获取链接
//			if (null == conn) {
//				throw new Exception("获取数据库连接异常,:DBPoolName" + DB_NAME);
//			}
//			//检查第三方用户是否存在
//			sql = "select " +
//					"ui.img_id,"+                   //
//					"ui.user_id,"+              //
//					"ui.img_desc,"+             //图片显示说明
//					"ui.img_size,"+             //图片大小
//					"ui.img_type,"+             //图片类型
//					"ui.img_old_file_name,"+    //图片原始文件名
//					"ui.img_new_file_name,"+    //图片上传后文件名
//					"ui.img_file_path,"+        //图片存储路径
//					"ui.img_url,"+              //图片访问URL
//					"ui.img_thum_url,"+         //缩略图url
//					"ui.upload_time,"+          //上传时间
//					"ui.state,"+                //1：正常显示； 2：删除
//					"ui.remark,"+               //
//					"ui.pack_id,"+              //
//					" ui.img_width , "+
//					" ui.img_height "+
//
//					" from t_user_up_img ui" +
//					" WHERE state = 1" +
//					" and ui.upload_day < :expireDate " +
//					" limit "+readCount+" ";
//			logger.info(msg_id + " - 查询过期的用户上传图片列表");
//			ps = new NamedParameterStatement(conn, sql);
//			ps.setInt("expireDate", Integer.parseInt(expireDate));
//			// 执行存储过程
//			rs = ps.executeQuery();
//			UserUpImg img = null;
//			while (rs != null && rs.next()) {
//				img = new UserUpImg();
//				img.imgId            = rs.getString("img_id");       //
//				img.userId           = rs.getString("user_id");   //
//				img.imgDesc          = rs.getString("img_desc");   //图片显示说明
//				img.imgSize          = rs.getString("img_size");   //图片大小
//				img.imgType          = rs.getString("img_type");   //图片类型
//				img.imgOldFileName = rs.getString("img_old_file_name");   //图片原始文件名
//				img.imgNewFileName = rs.getString("img_new_file_name");   //图片上传后文件名
//				img.imgFilePath     = rs.getString("img_file_path");   //图片存储路径
//				img.imgUrl           = rs.getString("img_url");   //图片访问URL
//				img.imgThumUrl      = rs.getString("img_thum_url");  //缩略图url
//				img.uploadTime       = rs.getString("upload_time");  //上传时间
//				img.state             = rs.getString("state");  //1：正常显示； 2：删除
//				img.remark            = rs.getString("remark");  //
//				img.packId            = rs.getString("pack_id");  //
//				img.imgWidth            = rs.getString("img_width");  //
//				img.imgHeight            = rs.getString("img_height");  //
//
//				oResult.add(img);
//			}
//
//			logger.info(msg_id + " - 查询过期的用户上传图片列表," +
//					"返回数据条数：" + oResult.size());
//			flag = true;
//		} catch (SQLException e) {
//			e.printStackTrace();
//			logger.error(msg_id + ":" + DB_NAME + " - " + sql + "执行异常:"
//					+ e.toString());
//		} catch (Exception e) {
//
//			logger.error(msg_id + ":" + DB_NAME + " - " + sql + "执行异常:"
//					+ e.toString());
//		} finally {
//			DBHelper.Instance().closeResource(conn, ps, rs); // 释放资源
//			return flag;
//		}
//	}
//
//
//	/**
//	 * 查询用户删除了的上传图片列表
//	 * @param msg_id
//	 * @return
//	 */
//	@SuppressWarnings("finally")
//	public static boolean find_user_delete_img_list(String msg_id,
//			String readCount, List<UserUpImg> oResult) {
//		boolean flag = false;
//
//		Connection conn = null;
//		ResultSet rs = null;
//		String sql = "";
//		NamedParameterStatement ps = null;
//		try {
//			conn = DBHelper.Instance().getConnection(msg_id, DB_NAME, logger); // 连接池获取链接
//			if (null == conn) {
//				throw new Exception("获取数据库连接异常,:DBPoolName" + DB_NAME);
//			}
//			//检查第三方用户是否存在
//			sql = "select " +
//					"ui.img_id,"+                   //
//					"ui.user_id,"+              //
//					"ui.img_desc,"+             //图片显示说明
//					"ui.img_size,"+             //图片大小
//					"ui.img_type,"+             //图片类型
//					"ui.img_old_file_name,"+    //图片原始文件名
//					"ui.img_new_file_name,"+    //图片上传后文件名
//					"ui.img_file_path,"+        //图片存储路径
//					"ui.img_url,"+              //图片访问URL
//					"ui.img_thum_url,"+         //缩略图url
//					"ui.upload_time,"+          //上传时间
//					"ui.state,"+                //1：正常显示； 2：删除
//					"ui.remark,"+               //
//					"ui.pack_id,"+              //
//					" ui.img_width , "+
//					" ui.img_height "+
//
//					" from t_user_up_img ui" +
//					" WHERE ui.state = 2 " +
//					" limit "+readCount+" ";
//			logger.info(msg_id + " - 查询已删除的用户上传表情组图片列表");
//			ps = new NamedParameterStatement(conn, sql);
//			// 执行存储过程
//			rs = ps.executeQuery();
//			UserUpImg img = null;
//			while (rs != null && rs.next()) {
//				img = new UserUpImg();
//				img.imgId            = rs.getString("img_id");       //
//				img.userId           = rs.getString("user_id");   //
//				img.imgDesc          = rs.getString("img_desc");   //图片显示说明
//				img.imgSize          = rs.getString("img_size");   //图片大小
//				img.imgType          = rs.getString("img_type");   //图片类型
//				img.imgOldFileName = rs.getString("img_old_file_name");   //图片原始文件名
//				img.imgNewFileName = rs.getString("img_new_file_name");   //图片上传后文件名
//				img.imgFilePath     = rs.getString("img_file_path");   //图片存储路径
//				img.imgUrl           = rs.getString("img_url");   //图片访问URL
//				img.imgThumUrl      = rs.getString("img_thum_url");  //缩略图url
//				img.uploadTime       = rs.getString("upload_time");  //上传时间
//				img.state             = rs.getString("state");  //1：正常显示； 2：删除
//				img.remark            = rs.getString("remark");  //
//				img.packId            = rs.getString("pack_id");  //
//				img.imgWidth            = rs.getString("img_width");  //
//				img.imgHeight            = rs.getString("img_height");  //
//
//				oResult.add(img);
//			}
//
//			logger.info(msg_id + " - 查询已删除的用户上传表情组图片列表," +
//					"返回数据条数：" + oResult.size());
//			flag = true;
//		} catch (SQLException e) {
//			e.printStackTrace();
//			logger.error(msg_id + ":" + DB_NAME + " - " + sql + "执行异常:"
//					+ e.toString());
//		} catch (Exception e) {
//
//			logger.error(msg_id + ":" + DB_NAME + " - " + sql + "执行异常:"
//					+ e.toString());
//		} finally {
//			DBHelper.Instance().closeResource(conn, ps, rs); // 释放资源
//			return flag;
//		}
//	}
//
//	/**
//	 * 删除过期图片后删除数据库数据
//	 * @return
//	 */
//	@SuppressWarnings("finally")
//	public static boolean prDeleteUserUpImgDB(String msg_id, String imgId) {
//		boolean flag = false;
//
//		Connection conn = null;
//		ResultSet rs = null;
//		String sql = "";
//		NamedParameterStatement ps = null;
//		try {
//			conn = DBHelper.Instance().getConnection(msg_id, DB_NAME, logger); // 连接池获取链接
//			if (null == conn) {
//				throw new Exception("获取数据库连接异常,:DBPoolName" + DB_NAME);
//			}
//
//			sql = " delete from t_user_up_img " +
//					" where img_id = :imgId ";
//
//			ps = new NamedParameterStatement(conn, sql);
//			ps.setString("imgId", imgId);
//			int count = ps.executeUpdate();
//
//			if(count>0){
//				flag = true;// 记录数据库输出参数
//				logger.info(msg_id + " - 删除过期图片[imgId:"+imgId+"]后删除数据库数据,完成");
//			}
//
//		} catch (Exception e) {
//			e.printStackTrace();
//			logger.error(msg_id + ":" + DB_NAME + " - " + sql + "执行异常:"
//					+ e.toString());
//		} finally {
//			DBHelper.Instance().closeResource(conn, ps, rs); // 释放资源
//			return flag;
//		}
//	}
//
//
//	/**
//	 * 删除用户删除的图片包数据
//	 * @return
//	 */
//	@SuppressWarnings("finally")
//	public static boolean prDeleteUserUpPackDB(String msg_id, String readCount) {
//		boolean flag = false;
//
//		Connection conn = null;
//		ResultSet rs = null;
//		String sql = "";
//		NamedParameterStatement ps = null;
//		try {
//			conn = DBHelper.Instance().getConnection(msg_id, DB_NAME, logger); // 连接池获取链接
//			if (null == conn) {
//				throw new Exception("获取数据库连接异常,:DBPoolName" + DB_NAME);
//			}
//
//			sql = " delete from t_user_up_pack " +
//					" where state <> 1" +
//					" limit "+readCount+" ";
//
//			ps = new NamedParameterStatement(conn, sql);
//			int count = ps.executeUpdate();
//
//			if(count>0){
//				flag = true;// 记录数据库输出参数
//				logger.info(msg_id + " - 删除过期图片包[readCount:"+readCount+"]数据,完成");
//			}
//
//		} catch (Exception e) {
//			e.printStackTrace();
//			logger.error(msg_id + ":" + DB_NAME + " - " + sql + "执行异常:"
//					+ e.toString());
//		} finally {
//			DBHelper.Instance().closeResource(conn, ps, rs); // 释放资源
//			return flag;
//		}
//	}
//
//
//
//	/**
//	 * 删除过期图片包数据库数据
//	 * @return
//	 */
//	@SuppressWarnings("finally")
//	public static boolean prDeleteExpireUserUpPackDB(String msg_id, String packId) {
//		boolean flag = false;
//
//		Connection conn = null;
//		ResultSet rs = null;
//		String sql = "";
//		NamedParameterStatement ps = null;
//		try {
//			conn = DBHelper.Instance().getConnection(msg_id, DB_NAME, logger); // 连接池获取链接
//			if (null == conn) {
//				throw new Exception("获取数据库连接异常,:DBPoolName" + DB_NAME);
//			}
//
//			sql = " delete from t_user_up_pack " +
//					" where pack_id = :packId ";
//
//			ps = new NamedParameterStatement(conn, sql);
//			ps.setString("packId", packId);
//			int count = ps.executeUpdate();
//
//			if(count>0){
//				flag = true;// 记录数据库输出参数
//				logger.info(msg_id + " - 删除过期图片包[packId:"+packId+"]删除数据库数据,完成");
//			}
//
//		} catch (Exception e) {
//			e.printStackTrace();
//			logger.error(msg_id + ":" + DB_NAME + " - " + sql + "执行异常:"
//					+ e.toString());
//		} finally {
//			DBHelper.Instance().closeResource(conn, ps, rs); // 释放资源
//			return flag;
//		}
//	}
//
//
//
//
//
//	/**
//	 * 重置制定id的任务
//	 * @return
//	 */
//	@SuppressWarnings("finally")
//	public static boolean prUpdateRunResultWait(String msg_id, String id) {
//		boolean flag = false;
//
//		Connection conn = null;
//		ResultSet rs = null;
//		String sql = "";
//		NamedParameterStatement ps = null;
//		try {
//			conn = DBHelper.Instance().getConnection(msg_id, DB_NAME,
//					logger); // 连接池获取链接
//			if (null == conn) {
//				throw new Exception("获取数据库连接异常,:DBPoolName" + DB_NAME);
//			}
//
//			sql = " update t_exp_task t " +
//					" set t.run_result = 0 " +
//					" where t.run_result = 1" +
//					" and t.id = :id";
//
//			ps = new NamedParameterStatement(conn, sql);
//			ps.setString("id", id);
//			int count = ps.executeUpdate();
//
//			if(count>0){
//				flag = true;
//				logger.info(msg_id + " - 重置task任务[id:"+id+"]执行状态,完成");
//			}
//		} catch (Exception e) {
//			e.printStackTrace();
//			logger.error(msg_id + ":" + DB_NAME + " - " + sql + "执行异常:"
//					+ e.toString());
//		} finally {
//			DBHelper.Instance().closeResource(conn, ps, rs); // 释放资源
//			return flag;
//		}
//	}
//
//
//
//	/**
//	 * 批量重置积分任务读取状态
//	 * @return
//	 */
//	@SuppressWarnings("finally")
//	public static boolean prBatchResetRunState( String msg_id) {
//		boolean flag = false;
//
//		Connection conn = null;
//		ResultSet rs = null;
//		String sql = "";
//		NamedParameterStatement ps = null;
//		try {
//			conn = DBHelper.Instance().getConnection(msg_id, DB_NAME,
//					logger); // 连接池获取链接
//			if (null == conn) {
//				throw new Exception("获取数据库连接异常,:DBPoolName" + DB_NAME);
//			}
//
//			sql = " update t_exp_task t " +
//					" set t.run_result = 0" +
//					" where t.run_result = 1";
//
//			ps = new NamedParameterStatement(conn, sql);
//			int count = ps.executeUpdate();
//			flag = true;
//			// 记录数据库输出参数
//			logger.info(msg_id + " - 重置积分任务状态,完成,修改数据"+count+"条");;
//		} catch (Exception e) {
//			logger.error(msg_id + ":" + DB_NAME + " - " + sql + "执行异常:"
//					+ e.toString());
//		} finally {
//			DBHelper.Instance().closeResource(conn, ps, rs); // 释放资源
//			return flag;
//		}
//	}
//
//	/**
//	 * 查询等待处理的task任务
//	 * @return
//	 */
//	@SuppressWarnings("finally")
//	public static boolean prFindWaitTaskList( String msg_id, String readCount, List<ExpInfo> oResult) {
//		boolean flag = false;
//
//		Connection conn = null;
//		ResultSet rs = null;
//		String sql = "";
//		NamedParameterStatement ps = null;
//		try {
//			conn = DBHelper.Instance().getConnection(msg_id, DB_NAME,
//					logger); // 连接池获取链接
//			if (null == conn) {
//				throw new Exception("获取数据库连接异常,:DBPoolName" + DB_NAME);
//			}
//
//			sql = " update t_exp_task t " +
//					" set t.run_result = 1," +
//					" t.run_cont = t.run_cont +1" +
//					" where t.run_result = 0" +
//					" limit "+readCount;
//
//			ps = new NamedParameterStatement(conn, sql);
//			int count = ps.executeUpdate();
//
//			if(count>0){
//				//查询任务是否添加过
//				sql = "select  " +
//						"t.id              ," +    //
//						"t.user_id         ," +    //
//						"t.exp_type_id     ," +    //经验类型
//						"t.relate_order_id ," +    //关联订单号
//						"t.opt_flag        ," +    //+/-；操作增减类型
//						"t.exp_num         ," +    //作操经验值
//						"t.opt_time        ," +    //操作的时间
//						"t.run_result      ," +    //0未执行；1执行中；2成功；3失败
//						"t.create_time     ," +    //
//						"t.run_cont 		" +    //行执次数
//						" from t_exp_task t" +
//						" where t.run_result = 1 " +
//						" limit 0, "+readCount;
//				ps = new NamedParameterStatement(conn, sql);
//				rs = ps.executeQuery();
//				ExpInfo exp = null;
//		        while (rs!=null && rs.next()) {
//		        	exp = new ExpInfo();
//		        	exp.id				= rs.getString("id");   //
//		        	exp.user_id			= rs.getString("user_id");   //
//		        	exp.exp_type_id		= rs.getInt	  ("exp_type_id"); // 经验类型
//		        	exp.relate_order_id	= rs.getString("relate_order_id");   // 	关联订单号
//		        	exp.opt_flag		= rs.getString("opt_flag");   //+/-；操作增减类型
//		        	exp.exp_num			= rs.getInt   ("exp_num");  // 作操经验值
//		        	exp.opt_time		= rs.getString("opt_time");   //操作的时间
//		        	exp.run_result		= rs.getInt   ("run_result");  // 0未执行；1执行中；2成功；失败
//		        	exp.create_time		= rs.getString("create_time");   //
//		        	exp.run_cont		= rs.getInt   ("run_cont");  // 行执次数
//		        	oResult.add(exp);
//				}
//			}
//
//			flag = true;
//			// 记录数据库输出参数
//			logger.info(msg_id + " - 查询等待执行的任务,完成,查询数据 "+oResult.size()+"条");;
//		} catch (Exception e) {
//			e.printStackTrace();
//			logger.error(msg_id + ":" + DB_NAME + " - " + sql + "执行异常:"
//					+ e.toString());
//		} finally {
//			DBHelper.Instance().closeResource(conn, ps, rs); // 释放资源
//			return flag;
//		}
//	}
//
//
//
//
//	/**
//	 * 添加积分经验task任务
//	 * @param msg_id
//	 * @param user_id
//	 * @param opt_time 操作时间
//	 * @param exp_type_id 经验操作类型
//	 * @param opt_flag 操作增减类型；+/-；
//	 * @param exp_num 操作经验值
//	 * @param oResult
//	 * @return
//	 */
//	@SuppressWarnings("finally")
//	public static boolean prAddExpTask(String msg_id,
//			String user_id, String opt_time, int exp_type_id, String relate_order_id,
//			String opt_flag, int exp_num, Map<String, String> oResult) {
//		boolean flag = false;
//
//		//积分操作0时，不操作
//		if(0 == exp_num){
//			return true;
//		}
//
//		Connection conn = null;
//		ResultSet rs = null;
//		String sql = "";
//		NamedParameterStatement ps = null;
//		try {
//			conn = DBHelper.Instance().getConnection(msg_id, DB_NAME,
//					logger); // 连接池获取链接
//			if (null == conn) {
//				throw new Exception("获取数据库连接异常,:DBPoolName" + DB_NAME);
//			}
//
//			//查询任务是否添加过
//			sql = "select count(1) dataCount" +
//					" from  t_exp_task t" +
//					" where t.id=:id" +
//					" or (t.exp_type_id = :exp_type_id" +
//						" and relate_order_id = :relate_order_id);";
//			logger.debug(msg_id + " - 查询关联订单[exp_type:"+exp_type_id+
//					"; id:"+relate_order_id+"]是否添加过");
//			ps = new NamedParameterStatement(conn, sql);
//			ps.setString("id", msg_id);
//			ps.setInt("exp_type_id", exp_type_id);
//			ps.setString("relate_order_id", relate_order_id);
//			rs = ps.executeQuery();
//			if(null != rs && rs.next() && 0 < rs.getInt("dataCount")){
//				logger.debug(msg_id + " - 查询关联订单[exp_type:"+exp_type_id+
//						"; id:"+relate_order_id+"]已经添加过");
//				flag = true;
//			} else {
//				sql = "INSERT INTO t_exp_task (id, user_id, exp_type_id, relate_order_id," +
//						"opt_flag, exp_num, opt_time, create_time, str_day)" +
//						" VALUE (" +
//						":id                , " +
//						":user_id           , " +
//						":exp_type_id       , " +
//						":relate_order_id   , " +
//						":opt_flag          , " +
//						":exp_num           , " +
//						":opt_time          , " +
//						":create_time		," +
//						" :str_day ) ;";
//				logger.debug(msg_id + " - 构建存储过程调用字符串:" + DB_NAME + " - " + sql);
//				ps = new NamedParameterStatement(conn, sql);
//				String id = IdMaker.GetUUID32();
//				ps.setString("id"               , id                );
//		        ps.setString("user_id"          , user_id           );
//		        ps.setInt("exp_type_id"      , exp_type_id       );
//		        ps.setString("opt_flag"         , opt_flag          );
//		        ps.setInt("exp_num"          , exp_num           );
//		        ps.setString("opt_time"         , opt_time          );
//		        ps.setString("relate_order_id"  , relate_order_id   );
//		        ps.setString("create_time"      , IdMaker.TimeFormat()  );
//		        ps.setString("str_day"      , IdMaker.DateFormat());
//
//		        if(ps.executeUpdate() > 0){
//		        	flag = true;
//		        }
//			}
//
//			// 记录数据库输出参数
//	        logger.info(msg_id + " - 添加关联订单[exp_type_id:"+exp_type_id+
//					"; id:"+relate_order_id+"]积分任务成功");
//		} catch (Exception e) {
//
//			logger.error(msg_id + ":" + DB_NAME + " - " + sql + "执行异常:"
//					+ e.toString());
//		} finally {
//			DBHelper.Instance().closeResource(conn, ps, rs); // 释放资源
//			return flag;
//		}
//	}
}
